#!/usr/bin/env python
# encoding: utf-8
"""
@Author: Beam
@Mail:506556658@qq.com
@file: pika_send.py
@time: 2017/5/17 11:04
"""


import pika
import datetime
credentials = pika.PlainCredentials('admin', 'admin')   #设置rabbitmq连接账号密码，默认是guest，guest
connection = pika.BlockingConnection(pika.ConnectionParameters('192.168.6.248',5672,'/',credentials))  #创建一个连接对象,对象中绑定了rabbitmq的IP
channel = connection.channel()  #建立连接通道
channel.queue_declare(queue='task_queue',durable=True)  #,#队列中声明指定queue,如果MQ中没有这个queue就创建,如果有,则略过，durable表示队列持久化，但不是队列数据持久化，不写的话mq服务退出，消息则会消息
message = 'Hello %s' % datetime.datetime.now()
channel.basic_publish(  #生产者把数据存放到mq
                      exchange='',
                      routing_key='task_queue',   #队列名称
                      body=message,   #消息内容
                      properties=pika.BasicProperties(delivery_mode=2,)   ##设置数据持久化时间为2天
                      )
print("[x] Sent %r" % message)
connection.close()